/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */
package com.jili.ubert.clientapi;

import com.jili.ubert.clientapi.until.TransferData;
import com.jili.ubert.clientapi.until.AnswerHandler;
import com.jili.ubert.clientapi.until.AbstractWorker;
import com.jili.ubert.clientapi.until.UnWorkException;
import com.jili.ubert.code.client2server.RequestPageData;
import com.jili.ubert.code.server2client.MsgResult;
import com.jili.ubert.code.server2client.PageDataProto;
import com.jili.ubert.dao.history.HistoryClearingCurrencyRates;
import com.jili.ubert.dao.history.HistoryIOPVAccount;
import com.jili.ubert.dao.history.HistoryIOPVProduct;
import com.jili.ubert.dao.history.HistoryIOPVProductUnit;
import com.jili.ubert.dao.history.HistoryLogLoginInfo;
import com.jili.ubert.dao.history.HistoryObjExRightInfo;
import com.jili.ubert.dao.history.HistoryTradeFundTransfer;
import com.jili.ubert.dao.history.HistoryTradesetCalendar;
import com.jili.ubert.dao.recent.RecentClearingAccountBail;
import com.jili.ubert.dao.recent.RecentClearingAccountFare;
import com.jili.ubert.dao.recent.RecentClearingDayBook;
import com.jili.ubert.dao.recent.RecentClearingExRight;
import com.jili.ubert.dao.recent.RecentClearingFundState;
import com.jili.ubert.dao.recent.RecentClearingPosDetail;
import com.jili.ubert.dao.recent.RecentClearingPrice;
import com.jili.ubert.dao.recent.RecentClearingProtfoliopos;
import com.jili.ubert.dao.recent.RecentObjETF;
import com.jili.ubert.dao.recent.RecentObjETFList;
import com.jili.ubert.dao.recent.RecentObjIndex;
import com.jili.ubert.dao.recent.RecentObjIndexList;
import com.jili.ubert.dao.recent.RecentTradeAlterOrder;
import com.jili.ubert.dao.recent.RecentTradeCancelOrder;
import com.jili.ubert.dao.recent.RecentTradeExecuteOrder;
import com.jili.ubert.dao.recent.RecentTradeNewOrder;
import com.jili.ubert.dao.recent.RecentTradeReportDetail;
import com.jili.ubert.dao.trace.TraceAccountBail;
import com.jili.ubert.dao.trace.TraceAccountFare;
import com.jili.ubert.dao.trace.TraceAccountIcode;
import com.jili.ubert.dao.trace.TraceAccountInfo;
import com.jili.ubert.dao.trace.TraceAccountInvest;
import com.jili.ubert.dao.trace.TraceBailTemp;
import com.jili.ubert.dao.trace.TraceBailTempObj;
import com.jili.ubert.dao.trace.TraceFareTemp;
import com.jili.ubert.dao.trace.TraceFareTempeObj;
import com.jili.ubert.dao.trace.TraceObjInfo;
import com.jili.ubert.dao.trace.TraceObjProtfolio;
import com.jili.ubert.dao.trace.TraceObjProtfolioList;
import com.jili.ubert.dao.trace.TraceObjUnderlying;
import com.jili.ubert.dao.trace.TraceProductAccount;
import com.jili.ubert.dao.trace.TraceProductInfo;
import com.jili.ubert.dao.trace.TraceProductUnit;
import com.jili.ubert.dao.trace.TraceRiskCtrlAssets;
import com.jili.ubert.dao.trace.TraceRiskSets;
import com.jili.ubert.dao.trace.TraceSafeForbidLogin;
import com.jili.ubert.dao.trace.TraceSafeOtherAccess;
import com.jili.ubert.dao.trace.TraceTradesetExchangeLimit;
import com.jili.ubert.dao.trace.TraceUserAccess;
import com.jili.ubert.dao.trace.TraceUserAccount;
import com.jili.ubert.dao.trace.TraceUserInfo;
import com.jili.ubert.dao.trace.TraceUserPrivateInfo;
import com.jili.ubert.dao.trace.TraceWorkFlowPath;
import com.jili.ubert.dao.trace.TraceWorkGroup;
import com.jili.ubert.dao.trace.TraceWorkGroupUser;
import com.jili.ubert.dao.trace.TraceWorkProductFlow;
import com.panemu.tiwulfx.common.TableCriteria;
import com.panemu.tiwulfx.common.TableData;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;
import javafx.scene.control.TableColumn;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

/**
 *
 * @author dragon
 */
public class HistoryDataRequest {
    private final SessionBucket sessionBucket = new SessionBucket();
    private static final Log log = LogFactory.getLog(HistoryDataRequest.class);
    private HistoryDataNettyClient client;
    private DataPool dataPool;
    public void setDataPool(DataPool datapool) {
        this.dataPool = datapool;
    }
    public HistoryDataRequest(){
        client = new HistoryDataNettyClient();
    }
    public HistoryDataRequest(String host, int port) {
        this.client = new HistoryDataNettyClient();
        MsgResult ret = client.Connect(host, port, false, false, this);
        if (!ret.getSuccess()) {
            throw new UnWorkException(ret.getWord());
        }
    }
    public MsgResult Connect(String host, int port, boolean isSSL, boolean isZlib) {
        return client.Connect(host, port, isSSL, isZlib, this);
    }
    public void setClient(HistoryDataNettyClient client) {
        this.client = client;
    }
    private AtomicInteger requstid = new AtomicInteger(0);

    private int getRequstID() {
        if (requstid.getAndIncrement() == Integer.MAX_VALUE) {
            requstid.getAndSet(Integer.MIN_VALUE);
        }
        return requstid.intValue();
    }
    /*
     handler调用区
     */

    public void AccpetSessionAnswer(int id, MsgEntity msg) {
        this.sessionBucket.OnDealSession(id, msg);
    }

    public void AccpetSessionFaileAnswer(int id, MsgResult msg) {
        this.sessionBucket.OnFaile(id, msg);
    }
    
    public int queryHistoryClearingCurrencyRatesList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<HistoryClearingCurrencyRates>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<HistoryClearingCurrencyRates> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(HistoryClearingCurrencyRates.DeCode(posb));} catch (IOException ex) {log.info("queryHistoryClearingCurrencyRatesList-PageDataProto fail decode:" + ex);}});TableData<HistoryClearingCurrencyRates> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryHistoryClearingCurrencyRatesList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(500, id, RequestPageData.EnCode(rpd));return id;}
public int queryHistoryIOPVAccountList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<HistoryIOPVAccount>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<HistoryIOPVAccount> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(HistoryIOPVAccount.DeCode(posb));} catch (IOException ex) {log.info("queryHistoryIOPVAccountList-PageDataProto fail decode:" + ex);}});TableData<HistoryIOPVAccount> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryHistoryIOPVAccountList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(501, id, RequestPageData.EnCode(rpd));return id;}
public int queryHistoryIOPVProductList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<HistoryIOPVProduct>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<HistoryIOPVProduct> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(HistoryIOPVProduct.DeCode(posb));} catch (IOException ex) {log.info("queryHistoryIOPVProductList-PageDataProto fail decode:" + ex);}});TableData<HistoryIOPVProduct> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryHistoryIOPVProductList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(502, id, RequestPageData.EnCode(rpd));return id;}
public int queryHistoryIOPVProductUnitList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<HistoryIOPVProductUnit>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<HistoryIOPVProductUnit> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(HistoryIOPVProductUnit.DeCode(posb));} catch (IOException ex) {log.info("queryHistoryIOPVProductUnitList-PageDataProto fail decode:" + ex);}});TableData<HistoryIOPVProductUnit> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryHistoryIOPVProductUnitList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(503, id, RequestPageData.EnCode(rpd));return id;}
public int queryHistoryLogLoginInfoList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<HistoryLogLoginInfo>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<HistoryLogLoginInfo> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(HistoryLogLoginInfo.DeCode(posb));} catch (IOException ex) {log.info("queryHistoryLogLoginInfoList-PageDataProto fail decode:" + ex);}});TableData<HistoryLogLoginInfo> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryHistoryLogLoginInfoList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(504, id, RequestPageData.EnCode(rpd));return id;}
public int queryHistoryObjExRightInfoList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<HistoryObjExRightInfo>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<HistoryObjExRightInfo> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(HistoryObjExRightInfo.DeCode(posb));} catch (IOException ex) {log.info("queryHistoryObjExRightInfoList-PageDataProto fail decode:" + ex);}});TableData<HistoryObjExRightInfo> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryHistoryObjExRightInfoList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(505, id, RequestPageData.EnCode(rpd));return id;}
public int queryHistoryTradeFundTransferList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<HistoryTradeFundTransfer>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<HistoryTradeFundTransfer> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(HistoryTradeFundTransfer.DeCode(posb));} catch (IOException ex) {log.info("queryHistoryTradeFundTransferList-PageDataProto fail decode:" + ex);}});TableData<HistoryTradeFundTransfer> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryHistoryTradeFundTransferList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(506, id, RequestPageData.EnCode(rpd));return id;}
public int queryHistoryTradesetCalendarList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<HistoryTradesetCalendar>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<HistoryTradesetCalendar> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(HistoryTradesetCalendar.DeCode(posb));} catch (IOException ex) {log.info("queryHistoryTradesetCalendarList-PageDataProto fail decode:" + ex);}});TableData<HistoryTradesetCalendar> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryHistoryTradesetCalendarList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(507, id, RequestPageData.EnCode(rpd));return id;}
public int queryRecentClearingAccountBailList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<RecentClearingAccountBail>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<RecentClearingAccountBail> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(RecentClearingAccountBail.DeCode(posb));} catch (IOException ex) {log.info("queryRecentClearingAccountBailList-PageDataProto fail decode:" + ex);}});TableData<RecentClearingAccountBail> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryRecentClearingAccountBailList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(508, id, RequestPageData.EnCode(rpd));return id;}
public int queryRecentClearingAccountFareList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<RecentClearingAccountFare>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<RecentClearingAccountFare> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(RecentClearingAccountFare.DeCode(posb));} catch (IOException ex) {log.info("queryRecentClearingAccountFareList-PageDataProto fail decode:" + ex);}});TableData<RecentClearingAccountFare> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryRecentClearingAccountFareList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(509, id, RequestPageData.EnCode(rpd));return id;}
public int queryRecentClearingDayBookList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<RecentClearingDayBook>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<RecentClearingDayBook> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(RecentClearingDayBook.DeCode(posb));} catch (IOException ex) {log.info("queryRecentClearingDayBookList-PageDataProto fail decode:" + ex);}});TableData<RecentClearingDayBook> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryRecentClearingDayBookList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(510, id, RequestPageData.EnCode(rpd));return id;}
public int queryRecentClearingExRightList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<RecentClearingExRight>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<RecentClearingExRight> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(RecentClearingExRight.DeCode(posb));} catch (IOException ex) {log.info("queryRecentClearingExRightList-PageDataProto fail decode:" + ex);}});TableData<RecentClearingExRight> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryRecentClearingExRightList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(511, id, RequestPageData.EnCode(rpd));return id;}
public int queryRecentClearingFundStateList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<RecentClearingFundState>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<RecentClearingFundState> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(RecentClearingFundState.DeCode(posb));} catch (IOException ex) {log.info("queryRecentClearingFundStateList-PageDataProto fail decode:" + ex);}});TableData<RecentClearingFundState> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryRecentClearingFundStateList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(512, id, RequestPageData.EnCode(rpd));return id;}
public int queryRecentClearingPosDetailList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<RecentClearingPosDetail>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<RecentClearingPosDetail> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(RecentClearingPosDetail.DeCode(posb));} catch (IOException ex) {log.info("queryRecentClearingPosDetailList-PageDataProto fail decode:" + ex);}});TableData<RecentClearingPosDetail> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryRecentClearingPosDetailList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(513, id, RequestPageData.EnCode(rpd));return id;}
public int queryRecentClearingPriceList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<RecentClearingPrice>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<RecentClearingPrice> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(RecentClearingPrice.DeCode(posb));} catch (IOException ex) {log.info("queryRecentClearingPriceList-PageDataProto fail decode:" + ex);}});TableData<RecentClearingPrice> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryRecentClearingPriceList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(514, id, RequestPageData.EnCode(rpd));return id;}
public int queryRecentClearingProtfolioposList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<RecentClearingProtfoliopos>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<RecentClearingProtfoliopos> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(RecentClearingProtfoliopos.DeCode(posb));} catch (IOException ex) {log.info("queryRecentClearingProtfolioposList-PageDataProto fail decode:" + ex);}});TableData<RecentClearingProtfoliopos> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryRecentClearingProtfolioposList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(515, id, RequestPageData.EnCode(rpd));return id;}
public int queryRecentObjETFList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<RecentObjETF>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<RecentObjETF> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(RecentObjETF.DeCode(posb));} catch (IOException ex) {log.info("queryRecentObjETFList-PageDataProto fail decode:" + ex);}});TableData<RecentObjETF> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryRecentObjETFList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(516, id, RequestPageData.EnCode(rpd));return id;}
public int queryRecentObjETFListList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<RecentObjETFList>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<RecentObjETFList> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(RecentObjETFList.DeCode(posb));} catch (IOException ex) {log.info("queryRecentObjETFListList-PageDataProto fail decode:" + ex);}});TableData<RecentObjETFList> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryRecentObjETFListList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(517, id, RequestPageData.EnCode(rpd));return id;}
public int queryRecentObjIndexList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<RecentObjIndex>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<RecentObjIndex> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(RecentObjIndex.DeCode(posb));} catch (IOException ex) {log.info("queryRecentObjIndexList-PageDataProto fail decode:" + ex);}});TableData<RecentObjIndex> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryRecentObjIndexList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(518, id, RequestPageData.EnCode(rpd));return id;}
public int queryRecentObjIndexListList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<RecentObjIndexList>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<RecentObjIndexList> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(RecentObjIndexList.DeCode(posb));} catch (IOException ex) {log.info("queryRecentObjIndexListList-PageDataProto fail decode:" + ex);}});TableData<RecentObjIndexList> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryRecentObjIndexListList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(519, id, RequestPageData.EnCode(rpd));return id;}
public int queryRecentTradeAlterOrderList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<RecentTradeAlterOrder>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<RecentTradeAlterOrder> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(RecentTradeAlterOrder.DeCode(posb));} catch (IOException ex) {log.info("queryRecentTradeAlterOrderList-PageDataProto fail decode:" + ex);}});TableData<RecentTradeAlterOrder> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryRecentTradeAlterOrderList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(520, id, RequestPageData.EnCode(rpd));return id;}
public int queryRecentTradeCancelOrderList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<RecentTradeCancelOrder>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<RecentTradeCancelOrder> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(RecentTradeCancelOrder.DeCode(posb));} catch (IOException ex) {log.info("queryRecentTradeCancelOrderList-PageDataProto fail decode:" + ex);}});TableData<RecentTradeCancelOrder> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryRecentTradeCancelOrderList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(521, id, RequestPageData.EnCode(rpd));return id;}
public int queryRecentTradeExecuteOrderList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<RecentTradeExecuteOrder>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<RecentTradeExecuteOrder> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(RecentTradeExecuteOrder.DeCode(posb));} catch (IOException ex) {log.info("queryRecentTradeExecuteOrderList-PageDataProto fail decode:" + ex);}});TableData<RecentTradeExecuteOrder> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryRecentTradeExecuteOrderList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(522, id, RequestPageData.EnCode(rpd));return id;}
public int queryRecentTradeNewOrderList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<RecentTradeNewOrder>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<RecentTradeNewOrder> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(RecentTradeNewOrder.DeCode(posb));} catch (IOException ex) {log.info("queryRecentTradeNewOrderList-PageDataProto fail decode:" + ex);}});TableData<RecentTradeNewOrder> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryRecentTradeNewOrderList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(523, id, RequestPageData.EnCode(rpd));return id;}
public int queryRecentTradeReportDetailList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<RecentTradeReportDetail>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<RecentTradeReportDetail> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(RecentTradeReportDetail.DeCode(posb));} catch (IOException ex) {log.info("queryRecentTradeReportDetailList-PageDataProto fail decode:" + ex);}});TableData<RecentTradeReportDetail> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryRecentTradeReportDetailList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(524, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceAccountBailList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceAccountBail>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceAccountBail> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceAccountBail.DeCode(posb));} catch (IOException ex) {log.info("queryTraceAccountBailList-PageDataProto fail decode:" + ex);}});TableData<TraceAccountBail> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceAccountBailList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(525, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceAccountFareList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceAccountFare>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceAccountFare> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceAccountFare.DeCode(posb));} catch (IOException ex) {log.info("queryTraceAccountFareList-PageDataProto fail decode:" + ex);}});TableData<TraceAccountFare> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceAccountFareList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(526, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceAccountIcodeList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceAccountIcode>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceAccountIcode> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceAccountIcode.DeCode(posb));} catch (IOException ex) {log.info("queryTraceAccountIcodeList-PageDataProto fail decode:" + ex);}});TableData<TraceAccountIcode> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceAccountIcodeList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(527, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceAccountInfoList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceAccountInfo>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceAccountInfo> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceAccountInfo.DeCode(posb));} catch (IOException ex) {log.info("queryTraceAccountInfoList-PageDataProto fail decode:" + ex);}});TableData<TraceAccountInfo> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceAccountInfoList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(528, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceAccountInvestList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceAccountInvest>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceAccountInvest> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceAccountInvest.DeCode(posb));} catch (IOException ex) {log.info("queryTraceAccountInvestList-PageDataProto fail decode:" + ex);}});TableData<TraceAccountInvest> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceAccountInvestList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(529, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceBailTempList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceBailTemp>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceBailTemp> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceBailTemp.DeCode(posb));} catch (IOException ex) {log.info("queryTraceBailTempList-PageDataProto fail decode:" + ex);}});TableData<TraceBailTemp> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceBailTempList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(530, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceBailTempObjList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceBailTempObj>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceBailTempObj> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceBailTempObj.DeCode(posb));} catch (IOException ex) {log.info("queryTraceBailTempObjList-PageDataProto fail decode:" + ex);}});TableData<TraceBailTempObj> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceBailTempObjList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(531, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceFareTempList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceFareTemp>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceFareTemp> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceFareTemp.DeCode(posb));} catch (IOException ex) {log.info("queryTraceFareTempList-PageDataProto fail decode:" + ex);}});TableData<TraceFareTemp> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceFareTempList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(532, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceFareTempeObjList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceFareTempeObj>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceFareTempeObj> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceFareTempeObj.DeCode(posb));} catch (IOException ex) {log.info("queryTraceFareTempeObjList-PageDataProto fail decode:" + ex);}});TableData<TraceFareTempeObj> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceFareTempeObjList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(533, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceObjInfoList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceObjInfo>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceObjInfo> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceObjInfo.DeCode(posb));} catch (IOException ex) {log.info("queryTraceObjInfoList-PageDataProto fail decode:" + ex);}});TableData<TraceObjInfo> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceObjInfoList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(534, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceObjProtfolioList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceObjProtfolio>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceObjProtfolio> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceObjProtfolio.DeCode(posb));} catch (IOException ex) {log.info("queryTraceObjProtfolioList-PageDataProto fail decode:" + ex);}});TableData<TraceObjProtfolio> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceObjProtfolioList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(535, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceObjProtfolioListList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceObjProtfolioList>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceObjProtfolioList> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceObjProtfolioList.DeCode(posb));} catch (IOException ex) {log.info("queryTraceObjProtfolioListList-PageDataProto fail decode:" + ex);}});TableData<TraceObjProtfolioList> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceObjProtfolioListList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(536, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceObjUnderlyingList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceObjUnderlying>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceObjUnderlying> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceObjUnderlying.DeCode(posb));} catch (IOException ex) {log.info("queryTraceObjUnderlyingList-PageDataProto fail decode:" + ex);}});TableData<TraceObjUnderlying> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceObjUnderlyingList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(537, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceProductAccountList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceProductAccount>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceProductAccount> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceProductAccount.DeCode(posb));} catch (IOException ex) {log.info("queryTraceProductAccountList-PageDataProto fail decode:" + ex);}});TableData<TraceProductAccount> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceProductAccountList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(538, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceProductInfoList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceProductInfo>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceProductInfo> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceProductInfo.DeCode(posb));} catch (IOException ex) {log.info("queryTraceProductInfoList-PageDataProto fail decode:" + ex);}});TableData<TraceProductInfo> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceProductInfoList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(539, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceProductUnitList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceProductUnit>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceProductUnit> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceProductUnit.DeCode(posb));} catch (IOException ex) {log.info("queryTraceProductUnitList-PageDataProto fail decode:" + ex);}});TableData<TraceProductUnit> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceProductUnitList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(540, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceRiskCtrlAssetsList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceRiskCtrlAssets>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceRiskCtrlAssets> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceRiskCtrlAssets.DeCode(posb));} catch (IOException ex) {log.info("queryTraceRiskCtrlAssetsList-PageDataProto fail decode:" + ex);}});TableData<TraceRiskCtrlAssets> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceRiskCtrlAssetsList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(541, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceRiskSetsList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceRiskSets>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceRiskSets> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceRiskSets.DeCode(posb));} catch (IOException ex) {log.info("queryTraceRiskSetsList-PageDataProto fail decode:" + ex);}});TableData<TraceRiskSets> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceRiskSetsList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(542, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceSafeForbidLoginList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceSafeForbidLogin>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceSafeForbidLogin> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceSafeForbidLogin.DeCode(posb));} catch (IOException ex) {log.info("queryTraceSafeForbidLoginList-PageDataProto fail decode:" + ex);}});TableData<TraceSafeForbidLogin> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceSafeForbidLoginList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(543, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceSafeOtherAccessList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceSafeOtherAccess>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceSafeOtherAccess> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceSafeOtherAccess.DeCode(posb));} catch (IOException ex) {log.info("queryTraceSafeOtherAccessList-PageDataProto fail decode:" + ex);}});TableData<TraceSafeOtherAccess> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceSafeOtherAccessList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(544, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceTradesetExchangeLimitList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceTradesetExchangeLimit>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceTradesetExchangeLimit> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceTradesetExchangeLimit.DeCode(posb));} catch (IOException ex) {log.info("queryTraceTradesetExchangeLimitList-PageDataProto fail decode:" + ex);}});TableData<TraceTradesetExchangeLimit> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceTradesetExchangeLimitList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(545, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceUserAccessList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceUserAccess>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceUserAccess> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceUserAccess.DeCode(posb));} catch (IOException ex) {log.info("queryTraceUserAccessList-PageDataProto fail decode:" + ex);}});TableData<TraceUserAccess> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceUserAccessList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(546, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceUserAccountList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceUserAccount>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceUserAccount> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceUserAccount.DeCode(posb));} catch (IOException ex) {log.info("queryTraceUserAccountList-PageDataProto fail decode:" + ex);}});TableData<TraceUserAccount> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceUserAccountList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(547, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceUserInfoList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceUserInfo>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceUserInfo> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceUserInfo.DeCode(posb));} catch (IOException ex) {log.info("queryTraceUserInfoList-PageDataProto fail decode:" + ex);}});TableData<TraceUserInfo> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceUserInfoList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(548, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceUserPrivateInfoList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceUserPrivateInfo>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceUserPrivateInfo> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceUserPrivateInfo.DeCode(posb));} catch (IOException ex) {log.info("queryTraceUserPrivateInfoList-PageDataProto fail decode:" + ex);}});TableData<TraceUserPrivateInfo> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceUserPrivateInfoList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(549, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceWorkFlowPathList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceWorkFlowPath>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceWorkFlowPath> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceWorkFlowPath.DeCode(posb));} catch (IOException ex) {log.info("queryTraceWorkFlowPathList-PageDataProto fail decode:" + ex);}});TableData<TraceWorkFlowPath> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceWorkFlowPathList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(550, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceWorkGroupList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceWorkGroup>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceWorkGroup> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceWorkGroup.DeCode(posb));} catch (IOException ex) {log.info("queryTraceWorkGroupList-PageDataProto fail decode:" + ex);}});TableData<TraceWorkGroup> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceWorkGroupList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(551, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceWorkGroupUserList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceWorkGroupUser>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceWorkGroupUser> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceWorkGroupUser.DeCode(posb));} catch (IOException ex) {log.info("queryTraceWorkGroupUserList-PageDataProto fail decode:" + ex);}});TableData<TraceWorkGroupUser> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceWorkGroupUserList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(552, id, RequestPageData.EnCode(rpd));return id;}
public int queryTraceWorkProductFlowList(int startIndex, List<TableCriteria> filteredColumns, List<String> sortedColumns, List<TableColumn.SortType> sortingOrders, int maxResult, AnswerHandler<TableData<TraceWorkProductFlow>> handler) throws IOException {int id = getRequstID();RequestPageData rpd = TransferData.getRequestPageData(startIndex, filteredColumns, sortedColumns, sortingOrders, maxResult);AbstractWorker worker = new AbstractWorker() {@Override public void Onhandler(MsgEntity msg) {PageDataProto data;try {data = PageDataProto.DeCode(msg.getData());List<TraceWorkProductFlow> datalist = new ArrayList<>(data.getMaxNum());data.getDataList().stream().forEach((byte[] posb) -> {try {datalist.add(TraceWorkProductFlow.DeCode(posb));} catch (IOException ex) {log.info("queryTraceWorkProductFlowList-PageDataProto fail decode:" + ex);}});TableData<TraceWorkProductFlow> data0 = new TableData<>(datalist,data.isMoreRows(),data.getTotalRows());getAnswerHandler().OnAnswer(data0);} catch (IOException ex) {log.info("queryTraceWorkProductFlowList fail decode:" + ex);}}};worker.setAnswerHandler(handler);this.sessionBucket.AcceptSession(id, worker);this.client.SendSYNCMsg(553, id, RequestPageData.EnCode(rpd));return id;}




}
